#include "BlockQueue.hpp"

using namespace BlockQueueM;

void* consumer(void* args)
{
    BlockQueue* bq=static_cast<BlockQueue*>(args);
    while(true)
    {
          
    }
}

void* productor(void* args)
{
    BlockQueue* bq=static_cast<BlockQueue*>(args);
    while(true)
    {
        
    }
}

int main()
{
//实现单生产/单消费
    BlockQueue* bq=new BlockQueue();
    //1、创建两线程
    pthread_t c,p;
    pthread_create(&c,nullptr,consumer,bq);
    pthread_create(&c,nullptr,productor,bq);

    return 0;
}